package com.thghh.gkrpc;

import com.tghhh.gkrpc.Peer;

import java.io.InputStream;

/**
 * >
 * <li>
 * 1.创建连接
 * 2.发送数据，并且等待响应
 * 3.关闭连接
 * </li>
 *
 * @author Zhikang.Peng
 * @version 1.0
 * @email thghh@qq.com
 * @date 2020/4/11 14:44
 */
public interface TransportClient {
    /**
     * 请求网络连接
     */
    void connect(Peer peer);

    /**
     * 发送数据，等待服务响应
     *
     * @param data 发送的数据
     * @return 服务器响应的数据流
     */
    InputStream write(InputStream data);

    /**
     * 关闭连接
     */
    void close();
}
